package com.Sinewecology.EntropyWechat;

import com.alibaba.fastjson.JSONObject;
import com.mchange.v2.log.FallbackMLog;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javax.net.ssl.HttpsURLConnection;
/*
import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLSocketFactory;
import javax.net.ssl.TrustManager;

import org.apache.http.HttpEntity;
import org.apache.http.ParseException;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.util.EntityUtils;
*/
//import org.apache.http.HttpResponse;
import java.io.BufferedReader;
//import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.ConnectException;
import java.net.URL;
/*
* 发送https请求
* @param requestUrl 请求地址
* @param requestMethod 请求方式（GET、POST）
* @param outputStr 提交的数据
* @return JSONObject(通过JSONObject.get(key)的方式获取json对象的属性值)
*/

public class WX_HttpsUtil {

    private static final Logger logger = LoggerFactory.getLogger(WX_HttpsUtil.class);

    public static JSONObject httpsRequest(String requestUrl, String requestMethod, String outputStr) {
/*    	System.out.println("发送取AccessToken的Get请求!");
        JSONObject jsonObject = null;
    	HttpClient client = HttpClientBuilder.create().build();//获取DefaultHttpClient请求
	    HttpGet httpGet = new HttpGet(requestUrl);//HttpGet将使用Get方式发送请求URL
	    HttpResponse response = client.execute(httpGet);//使用HttpResponse接收client执行httpGet的结果
	    HttpEntity entity = response.getEntity();//从response中获取结果，类型为HttpEntity
	    if(entity != null){
	    	String result = EntityUtils.toString(entity,"UTF-8");//HttpEntity转为字符串类型
	        jsonObject = JSONObject.parseObject(result);//  .fromObject(result);//字符串类型转为JSON类型
	    }
        return jsonObject;
*/
        JSONObject jsonObject = null;
//        logger.info("发送"+requestMethod+"请求!");
        try {
            // 创建SSLContext对象，并使用我们指定的信任管理器初始化
//        	MyX509TrustManager[] tm ={ new  MyX509TrustManager() };
//            SSLContext sslContext = SSLContext.getInstance("SSL", "SunJSSE");
//            sslContext.init(null, (TrustManager[])tm, new java.security.SecureRandom());
            // 从上述SSLContext对象中得到SSLSocketFactory对象
//            SSLSocketFactory ssf = sslContext.getSocketFactory();
            URL url = new URL(requestUrl);
            HttpsURLConnection conn = (HttpsURLConnection) url.openConnection();
//            conn.setSSLSocketFactory(ssf);
            conn.setDoOutput(true);
            conn.setDoInput(true);
            conn.setUseCaches(false);
            // 设置请求方式（GET/POST）
            conn.setRequestMethod(requestMethod);
            // 当outputStr不为null时向输出流写数据
            if (null != outputStr) {
                OutputStream outputStream = conn.getOutputStream();
                // 注意编码格式
                outputStream.write(outputStr.getBytes("UTF-8"));
                outputStream.close();
            }
            // 从输入流读取返回内容
            InputStream inputStream = conn.getInputStream();
            InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8");
            BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
            String str = null;
            StringBuffer buffer = new StringBuffer();
            while ((str = bufferedReader.readLine()) != null) {
                buffer.append(str);
            }
            // 释放资源
            bufferedReader.close();
            inputStreamReader.close();
            inputStream.close();
            inputStream = null;
            conn.disconnect();
            jsonObject = JSONObject.parseObject(buffer.toString());
        } catch (ConnectException ce) {
            logger.info("连接超时");
        } catch (Exception e) {
        	e.printStackTrace();
            logger.info("https请求异常");
            while(true);
        }
        return jsonObject;
    }
}
